#!/usr/bin/env python
# -*- coding: utf-8 -*-
#-----------------------
# Name: tmdb_request.py
# Python Library
# Author: Raymond Wagner
# Purpose: Wrapped urllib2.Request class pre-configured for accessing the
#          TMDb v3 API
#-----------------------


from .tmdb_exceptions import *
from .locales import get_locale
from .cache import Cache

from urllib.parse import urlencode
import urllib.request
import urllib.error
import urllib.parse
import json
import os

DEBUG = False
cache = Cache(filename='pytmdb3.cache')

#DEBUG = True
#cache = Cache(engine='null')


def set_key(key):
    """
    Specify the API key to use retrieving data from themoviedb.org.
    This key must be set before any calls will function.
    """
    if len(key) != 32:
        raise TMDBKeyInvalid("Specified API key must be 128-bit hex")
    try:
        int(key, 16)
    except:
        raise TMDBKeyInvalid("Specified API key must be 128-bit hex")
    Request._api_key = key


def set_cache(engine=None, *args, **kwargs):
    """Specify caching engine and properties."""
    cache.configure(engine, *args, **kwargs)


class Request(urllib.request.Request):
    _api_key = None
    _base_url = "http://api.themoviedb.org/3/"

    @property
    def api_key(self):
        if self._api_key is None:
            raise TMDBKeyMissing("API key must be specified before " +
                                 "requests can be made")
        return self._api_key

    def __init__(self, url, **kwargs):
        """
        Return a request object, using specified API path and
        arguments.
        """
        kwargs['api_key'] = self.api_key
        self._url = url.lstrip('/')
        self._kwargs = dict([(kwa, kwv) for kwa, kwv in list(kwargs.items())
                                        if kwv is not None])

        locale = get_locale()
        kwargs = {}
        for k, v in list(self._kwargs.items()):
            if isinstance(v, str):
                kwargs[k] = v.encode('utf-8')
            else:
                kwargs[k] = str(v)
        url = '{0}{1}?{2}'.format(self._base_url, self._url, urlencode(kwargs))

        urllib.request.Request.__init__(self, url)
        self.add_header('Accept', 'application/json')
        self.lifetime = 3600  # 1hr

    def new(self, **kwargs):
        """
        Create a new instance of the request, with tweaked arguments.
        """
        args = dict(self._kwargs)
        for k, v in list(kwargs.items()):
            if v is None:
                if k in args:
                    del args[k]
            else:
                args[k] = v
        obj = self.__class__(self._url, **args)
        obj.lifetime = self.lifetime
        return obj

    def add_data(self, data):
        """Provide data to be sent with POST."""
        urllib.request.Request.add_data(self, urlencode(data))

    def open(self):
        """Open a file object to the specified URL."""
        try:
            if DEBUG:
                print('loading ' + self.get_full_url())
                if self.has_data():
                    print('  ' + self.get_data())
            return urllib.request.urlopen(self)
        except urllib.error.HTTPError as e:
            raise TMDBHTTPError(e)

    def read(self):
        """Return result from specified URL as a string."""
        return self.open().read()

    @cache.cached(urllib.request.Request.get_full_url)
    def readJSON(self):
        """Parse result from specified URL as JSON data."""
        url = self.get_full_url()
        try:
            # catch HTTP error from open()
            data = json.load(self.open())
        except TMDBHTTPError as e:
            try:
                # try to load whatever was returned
                data = json.loads(e.response)
            except:
                # cannot parse json, just raise existing error
                raise e
            else:
                # response parsed, try to raise error from TMDB
                handle_status(data, url)
            # no error from TMDB, just raise existing error
            raise e
        handle_status(data, url)
        if DEBUG:
            import pprint
            pprint.PrettyPrinter().pprint(data)
        return data


status_handlers = {
    1: None,                    # Success
    2: TMDBRequestInvalid,      # Invalid service
    3: TMDBRequestError,        # Authentication failed
    4: TMDBRequestInvalid,      # Invalid format
    5: TMDBRequestInvalid,      # Invalid parameters
    6: TMDBRequestInvalid,      # Invalid id
    7: TMDBKeyInvalid,          # Invalid API key
    8: TMDBRequestError,        # Duplicate entry
    9: TMDBOffline,             # Service offline
    10: TMDBKeyRevoked,         # Suspended API key
    11: TMDBError,              # Internal error
    12: None,                   # Item update success
    13: None,                   # Item delete success
    14: TMDBRequestError,       # Authentication failed
    15: TMDBError,              # Failed
    16: TMDBError,              # Device denied
    17: TMDBError,              # Session denied
    18: TMDBRequestError,       # Validation denied
    19: TMDBRequestInvalid,     # Invalid accept header
    20: TMDBRequestInvalid,     # Invalid date range
    21: TMDBRequestError,       # Entry not found
    22: TMDBPagingIssue,        # Invalid page
    23: TMDBRequestInvalid,     # Invalud date
    24: TMDBError,              # Request time out
    25: TMDBRequestError,       # Request limit reached
    26: TMDBRequestInvalid,     # Missing usernam and password
    27: TMDBRequestError,       # Too many append
    28: TMDBRequestInvalid,     # Invalud timezone
    29: TMDBRequestInvalid,     # Action confirmation required
    30: TMDBRequestError,       # Invalid username or password
    31: TMDBRequestError,       # Accound disabled
    32: TMDBRequestError,       # Email not verified,
    33: TMDBKeyInvalid,         # Invalud request token
    34: TMDBRequestError        # Resource could not be found
}


def handle_status(data, query):
    status_code = data.get('status_code', 1)
    exception_class = status_handlers[status_code]
    if exception_class is not None:
        status_message = data.get('status_message', None)
        status = exception_class(status_message)
        status.tmdberrno = status_code
        status.query = query
        raise status
